package app.processor;

import org.ricks.net.Listener;
import org.ricks.net.AioSession;

import java.nio.ByteBuffer;

/**
 * @author chenwei
 * @Title:
 * @Package
 * @Description:
 * @date 2022/11/314:03
 */
public class ChannelListener implements Listener {

    @Override
    public void onConnected(AioSession session) {
        System.err.println(session.getSessionID() +": 连接上了。。。。。。。");
    }

    @Override
    public void handleReceive(ByteBuffer byteBuf, AioSession session) {

    }

    @Override
    public void handleException(Throwable ex, AioSession session) {
        System.err.println(session.getSessionID() +": 发生异常。。。。。。。");
    }

    @Override
    public void handleClose(AioSession session) {
        System.err.println(session.getSessionID() +": 连接关闭。。。。。。。");
    }
}
